package com.guo.core.framework.arrange.notice;

import com.guo.core.framework.arrange.ArrangeNotice;
import com.guo.core.framework.observable.BizObserver;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class OpmsObserver implements BizObserver<ArrangeNotice> {

    @Override
    public void consume(ArrangeNotice data) throws InterruptedException {
        log.info("OPMS消费数据：{}", data);
        Thread.sleep(3000L);
    }

}
